<?php

// Create a document instance 
require 'simple_dom.php';
include 'connection.php';

function replace_class($file_contents) {
    return str_replace('class=""', 'class="prix"', $file_contents);
}

function collectData($chemin_fichier_html) {

    $html = file_get_html($chemin_fichier_html);
    $produit = $html->find('h1', 0)->plaintext;
    $val = mysql_real_escape_string($produit) . '<br />';
    $query_produit = "INSERT INTO produit (Libelle) values ('$val');";
    if (!mysql_query($query_produit)) {
        //die('Error: ' . mysql_error());
    } else {
        
    }
    $qery_id_produit = "SELECT id_produit FROM produit where Libelle = '$val'";
    $result = mysql_query($qery_id_produit) or die(mysql_error());
    $id = mysql_fetch_array($result) or die(mysql_error());
    $id_produit = $id['id_produit'];
    mysql_free_result($result);

    foreach ($html->find('tbody tr') as $tb) {
        $produit = $tb->find('.imgProduitMdd', 0);
        if (!is_null($produit)) {
            $ens =  $tb->find('.imgProduitMdd', 0)->alt;            
            $query_ens = "INSERT INTO enseigne (Nom) values ('$ens');";
            if (!mysql_query($query_ens)) {
                //die('Error: ' . mysql_error());
            } else {
                
            }            
        }
    }
    
    foreach ($html->find('tbody tr') as $tb) {
        $produit = $tb->find('.imgProduitMdd', 0);
        if (!is_null($produit)) {
            $ens =  $tb->find('.imgProduitMdd', 0)->alt;  
            $qery_id_ens = "SELECT id_enseigne FROM enseigne where Nom like '$ens'";
            $result = mysql_query($qery_id_ens) or die(mysql_error());
            $id = mysql_fetch_array($result) or die(mysql_error());
            mysql_free_result($result);
            $id_ens = $id['id_enseigne'];
            $prix = preg_replace('/[^a-zA-Z0-9_%\[().\]\\/-]/s','',$tb->find('[headers="header3"]', 0)->plaintext);
            $query_prix = "INSERT INTO prix_produit (id_produit,id_enseigne,prix) values ($id_produit,$id_ens,$prix);";
            if (!mysql_query($query_prix)) {
                $query_prix_update = "UPDATE prix_produit SET prix=$prix where id_produit=$id_produit and id_enseigne = $id_ens";
                mysql_query($query_prix_update) or die(mysql_error());
            } else {
                
            }
        }
    }
    //$GLOBALS['cpt'] = $GLOBALS['cpt'] + 1;   
}

$dossier_depart = 'D:/dataTest/';
$fichiers = array();
if (is_dir($dossier_depart)) {
    if ($dh = opendir($dossier_depart)) {
        while (($fic = readdir($dh)) !== false) {
            if (!in_array($fic, array('.', '..')))
                $fichiers[] = $dossier_depart . $fic;
        }
        closedir($dh);
    }
    else
        echo $dossier_depart . ' n\'est pas un repertoire valide!';
}
else
    echo $dossier_depart . ' n\'est pas un repertoire !';

sort($fichiers);

//for ($i = 1; $i <= 70; $i++){
foreach ($fichiers as $chemin_fichier) {
    //
    collectData($chemin_fichier);

    // $fichierdep = explode("/", $fichiers[$i]);
    // if (copy($fichiers[$i],'D:/dataMove/'.$fichierdep[2])) {
    //   unlink($fichiers[$i]);
    // }
}
//echo htmlentities(utf8_decode("Mise à jour effectué : ".$cpt));
?>
